package main

import (
	"mq/config"
	"mq/utils"
	"time"
)

func main() {
	ticker := time.NewTicker(time.Millisecond * 100)
	defer ticker.Stop()

	for range ticker.C {
		_, msg := utils.RandomNormalInt64(config.MIN, config.MAX, config.MIU, config.SIGMA)
		utils.SendSyncMessage(config.NORMALITY_TROPIC, utils.Int64ToBytes(msg), utils.Myproducer)
	}

}
